package com.world.rickcloudendpoint.queue;

import java.nio.channels.FileChannel;
import java.util.concurrent.atomic.AtomicLong;

/**
 * @description: 队列对象
 * @author: 徐靖峰
 * @date: 2022/06/02 14:10:54
 * @version: 1.0
 */
public class Queue {

    public final static int SINGLE_MESSAGE_SIZE = 58;
    public final static int BLOCK_SIZE = 40;

    private FileChannel channel;
    private AtomicLong wrotePosition; // 写的位置

    private volatile boolean firstGet = true;
    private volatile  boolean firstPut = true;
}
